const mysql = require('mysql');
//引入配置文件
const {dbconfig} = require('../config.js');
//创建数据库连接池
const pool = mysql.createPool(dbconfig);

let db = {};

//进行sql语句的执行和执行结果的返回
db.q = (sql,params) =>{
	return new Promise((resolve,reject) =>{
		//从池子里获取连接对象
		pool.getConnection((err,connection) =>{
			//如果连接对象获取失败，失败信息就传递给err
			if(err){
				reject(err);
				return;
			}
			//释放连接对象
			connection.release();
			//如果获取成功，连接对象传递给connection
			connection.query(sql,params,(err,result) =>{
				if(err){
					reject(err);
					return;
				}
				resolve(result);
			})
		})
	})
}
module.exports = db;



